# -*- coding:utf-8 -*-

__author__ = 'ghostviper'

# Kafka server information'
KAFKA_SETTINGS = {
    'KAFKA_HOSTS': ['localhost:9092'],
    'KAFKA_INCOMING_TOPIC': 'demo.incoming',
    'KAFKA_GROUP': 'demo-group',
    'KAFKA_FEED_TIMEOUT': 10,
    'KAFKA_CONSUMER_AUTO_OFFSET_RESET': 'earliest',
    'KAFKA_CONSUMER_TIMEOUT': 50,
    'KAFKA_CONSUMER_COMMIT_INTERVAL_MS': 5000,
    'KAFKA_CONSUMER_AUTO_COMMIT_ENABLE': True,
    'KAFKA_CONSUMER_FETCH_MESSAGE_MAX_BYTES': 10 * 1024 * 1024,
    'KAFKA_PRODUCER_BATCH_LINGER_MS': 25,
    'KAFKA_PRODUCER_BUFFER_BYTES': 4 * 1024 * 1024,
}

# BloomFilter config
BLOOMFILTER_SETTINGS = {
    'host': 'localhost',
    'port': 6379,
    'db': 1,
    'blockNum': 1,
    'key': 'bloomfilter'
}

